package cn.fu.service;

import java.util.Map;

import javax.servlet.http.HttpServletRequest;

import org.apache.log4j.Logger;

import cn.fu.robot.TulingApiProcess;
import cn.fu.service.autoReply.MessageResponse;
import cn.fu.service.messReply.MessageReply;
import cn.fu.util.Const;
import cn.fu.util.MessageUtil;
import cn.fu.util.WeixinUtil;

public class CoreService {

	
	private Logger log = Logger.getLogger(CoreService.class);
	
	/**
	 * 处理微信发来的请求
	 * 
	 * @param request
	 * @return
	 */
	public static String processRequest(HttpServletRequest request) {
		String respMessage = null;
		try {
			// 默认返回的文本消息内容
			String respContent = Const.REQUEST_EXCEPTION;//消息处理异常

			// xml请求解析
			// 调用消息工具类MessageUtil解析微信发来的xml格式的消息，解析的结果放在HashMap里；
			Map<String, String> requestMap = MessageUtil.xmlToMap(request);

			// 从HashMap中取出消息中的字段；
			// 发送方帐号（open_id）
			String fromUserName = requestMap.get("FromUserName");
			// 公众帐号
			String toUserName = requestMap.get("ToUserName");
			// 消息类型
			String msgType = requestMap.get("MsgType");
			// 消息内容
			String content = requestMap.get("Content");
			// 从HashMap中取出消息中的字段；
			

			// 文本消息
			if (msgType.equals(Const.REQ_MESSAGE_TYPE_TEXT)) {
				//微信聊天自动回复
				if(content!=null){
					//机器人api
					if("robot".equals(Const.REPLY_TYPE)){
						//调用图灵的自动回复
						respContent = TulingApiProcess.getTulingResult(content);
					}else{
						//自定义消息回复  (返回文本，图文，菜单等)
						MessageReply messageReply=new MessageReply();
						return  messageReply.textReply(fromUserName,toUserName,msgType,content);
					}
					//如果得不到回复信息
					if(respContent==""||null==respContent){
						MessageResponse.textMessageToXml(fromUserName , toUserName , Const.TEXTMESSAGE_ERRO);//服务号暂时无法回复，请稍后再试
					}
					return MessageResponse.textMessageToXml(fromUserName , toUserName , respContent);
				}
//				else if (content.startsWith("ZY")) {//查作业
//					String keyWord = content.replaceAll("^ZY" , "").trim();
//					if ("".equals(keyWord)) {
//						respContent = AutoReply.getXxtUsage("24");
//					} else {
//						return XxtService.getHomework("24" , fromUserName , toUserName , keyWord);
//					}
//				} else if (content.startsWith("SJX")) {//收件箱
//					String keyWord = content.replaceAll("^SJX" , "").trim();
//					if ("".equals(keyWord)) {
//						respContent = AutoReply.getXxtUsage("25");
//					} else {
//						return XxtService.getRecvBox("25" , fromUserName , toUserName , keyWord);
//					}
//				}
//				return MessageResponse.getTextMessage(fromUserName , toUserName , respContent);
			} else if (msgType.equals(Const.REQ_MESSAGE_TYPE_EVENT)) {// 事件推送
				String eventType = requestMap.get("Event");// 事件类型
				
				if (eventType.equals(Const.EVENT_TYPE_SUBSCRIBE)) {// 订阅
					//respContent = Const.WELCOME_FOLLOW;//欢迎订阅信息
					//return MessageResponse.textMessageToXml(fromUserName , toUserName , respContent);
					//调出主菜单
					return MessageResponse.textMessageToXml(fromUserName , toUserName ,WeixinUtil.menuText());
				} else if (eventType.equals(Const.EVENT_TYPE_UNSUBSCRIBE)) {// 取消订阅
					// TODO 取消订阅后用户再收不到公众号发送的消息，因此不需要回复消息
				} else if (eventType.equals(Const.EVENT_TYPE_CLICK)) {// 自定义菜单点击事件
					String eventKey = requestMap.get("EventKey");// 事件KEY值，与创建自定义菜单时指定的KEY值对应
					return MenuClickService.getClickResponse(eventKey , fromUserName , toUserName);
				}
			}
			
			
			
			
			
			//开启微信声音识别测试 
			else if(msgType.equals("voice"))
			{
				String recvMessage = requestMap.get("Recognition");
				//respContent = "收到的语音解析结果："+recvMessage;
				if(recvMessage!=null){
					respContent = TulingApiProcess.getTulingResult(recvMessage);
				}else{
					respContent = "您说的太模糊了，能不能重新说下呢？";
				}
				return MessageResponse.textMessageToXml(fromUserName , toUserName , respContent); 
			}
			//拍照功能
			else if(msgType.equals("pic_sysphoto"))
			{
				
			}
			else
			{
				return MessageResponse.textMessageToXml(fromUserName , toUserName , "返回为空"); 
			}
			
			
			
			
			
		}
		catch (Exception e) {
			e.printStackTrace();
		}

		return respMessage;
	}

}
